package com.liuyi.netty.mqtt.processed.process;

import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.mqtt.MqttMessage;

/**
 * Mqtt 消息处理
 */
public interface MqttProcess {

    /**
     * 处理方式
     */
    void process(ChannelHandlerContext channel, MqttMessage msg);
}
